package main

import (
	"fmt"
	"github.com/Shopify/sarama"
)

func main() {
	// kafka 初始化连接
	config := sarama.NewConfig()
	config.Producer.Return.Successes = true

	client, err := sarama.NewClient([]string{"162.14.70.254:9092"}, config)
	if err != nil {
		panic(err)
	}
	fmt.Println("client start...", client)
}
